package com.chb.storm.gpstrident;

import java.util.Map;

import storm.trident.state.State;
import storm.trident.state.StateFactory;
import backtype.storm.task.IMetricsContext;

public class GpsHbaseStateFactory implements StateFactory {

	/**
	 * 
	 */
	private static final long serialVersionUID = 7824191560324774871L;

	@Override
	public State makeState(Map conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
		GpsHbaseState state = new GpsHbaseState(conf, numPartitions, partitionIndex);
		return state;
	}

}
